//package lzzsrj.union.message.redis;
//
//import com.alibaba.fastjson.JSON;
//import org.springframework.data.redis.core.RedisTemplate;
//
//import java.time.LocalDateTime;
//
//public class RedisMQSender {
//    private RedisTemplate<String, Object> redisTemplate;
//
//    public RedisMQSender(RedisTemplate<String, Object> redisTemplate) {
//        this.redisTemplate = redisTemplate;
//    }
//
//    public void send(String queue, Object msg) {
//        redisTemplate.opsForList().leftPush(queue,
//                JSON.toJSONString(new RedisMQMessage()
//                        .setQueue(queue)
//                        .setLocalDateTime(LocalDateTime.now())
//                        .setData(msg)));
//    }
//}
//
